package org.hyl.javaext.disruptor;

import com.lmax.disruptor.EventHandler;


public class DisruptorConsumer2  implements EventHandler<FileData> {
    private static final String FINIDHED = "EOF";

    private int index;//������id

    public DisruptorConsumer2(int i){
        this.index = i;
    }

    public DisruptorConsumer2(){}

 
    public void onEvent(FileData event, long sequence, boolean endOfBatch) throws InterruptedException {
    	   String line = event.getLine();
           // ����
           System.out.println("c"+this.index +" :"+line);
            if (line.equals(FINIDHED)) {
                return;
            }
    }
}